//package com.yupi.springbootinit.messagecenter;
//
//import jakarta.annotation.Resource;
//import lombok.extern.slf4j.Slf4j;
//import org.springframework.scheduling.annotation.Scheduled;
//import org.springframework.stereotype.Component;
//
//// @Component  // RabbitMQ 已暂停使用
//@Slf4j
//public class OutboxPublishScheduler {
//
//    @Resource
//    private RabbitOutboxPublisher publisher;
//
//    /**
//     * 每5秒扫描一次待发送事件，应用启动10秒后开始
//     */
//    // @Scheduled(initialDelay = 10_000, fixedDelay = 5_000)  // RabbitMQ 已暂停使用
//    public void scanAndPublish() {
//        try {
//            publisher.publishPendingBatch(50);
//        } catch (Exception e) {
//            log.warn("Outbox scheduler run failed", e);
//        }
//    }
//}